package com.atguigu.edu.realtime.common;


import org.apache.kafka.clients.consumer.ConsumerConfig;

/**
 * @ClassName: KafkaConnectorConfig
 * @Description: TODO Kafka连接常量类
 * @Author: zhaoxunfeng
 * @Date: 2022-08-31 10:24
 * @Version: 1.0.0
 */
public interface KafkaConnectorConfig {

    // kafka云服务器连接地址
    String KAFKA_BROKER_LIST = "39.108.149.44:9092,112.74.53.189:9092,120.77.81.212:9092";

    // kafka本地集群测试连接地址
    String KAFKA_BROKER_LIST_TEST = "hadoop102:9092,hadoop103:9092,hadoop104:9092";

    // kafka消费者消费策略
    String OFFSET_STRATEGY = "latest";

    // kafka隔离级别
    String READ_COMMITTED = "read_committed";

    // kafka生产者事务超时时间：15min
    String TRANSACTION_TIMEOUT = 60 * 15 * 1000 + "";

}
